#include "db.h"
#include "sqlite3.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <time.h>
#include <unistd.h>
#include <stdlib.h>

//客户端通信模块 获取数据请求接口 调用request_temp_humi函数
//获取数据请求
int request_temp_humi(void)
{
	uint16_t i = 0;
	while(1)
	{
		sleep(1); //被主通讯模块调用时注释
		db_insert(i, i+10, i+100);
		i++;
	}
	return 0;
}
//读取数据库代码 客户端通信模块
void read_db(void)
{
	int m,n,l,j;
	while(1)
	{
		printf("请输入查询项目：");
		scanf("%d",&l);
		printf("请输入开始条数：");
		scanf("%d",&m);
		printf("请输入查询条数：");
		scanf("%d",&n);
		int ret = db_seek(l,m,n);
		if(-1 == ret)
		{
			printf("your input error,please retry\r\n");
			continue;
		}
		for(j = 0;j < n;j++)
		{
			printf("%s:%s\r\n",pptable[0],pptable[j+1]);
		}
	}
}
int main(void)
{
	system("clear");

	db_init();
	pid_t pid = fork();
	if(pid == -1)
	{
		perror("fork error");
		return -1;
	}
	else if(pid == 0)
	{
		request_temp_humi();
		exit(0);
	}
	else if(pid > 0)
	{
		read_db();
		exit(0);
	}

	return 0;
}
